package com.swak.reactivex.transport;

import java.util.concurrent.CompletionStage;

import com.swak.exception.RemotingException;

public interface ExchangeHandler extends ChannelHandler {

    /**
     * reply.
     *
     * @param channel
     * @param message
     * @return response
     * @throws RemotingException
     */
	CompletionStage<Object> reply(ExchangeChannel channel, Object message) throws RemotingException;

}
